import requests
import json

BASE = "http://localhost:8080"

def simulate_task_error():
    """手动模拟一个任务的错误状态"""
    
    # 获取所有任务
    response = requests.get(f"{BASE}/api/tasks")
    tasks = response.json()
    
    if not tasks:
        print("没有找到任务")
        return
    
    # 选择第一个任务来模拟错误
    task = tasks[0]
    task_id = task['id']
    
    print(f"模拟任务 {task['name']} (ID: {task_id}) 的错误...")
    
    # 更新任务状态为错误
    task['failed'] = 5
    task['lastErrorMsg'] = "模拟错误：无法连接到 RabbitMQ 队列 'nonexistent_queue'"
    task['lastErrorAt'] = "2025-08-15T15:59:25.000Z"
    
    # 发送更新请求
    response = requests.post(f"{BASE}/api/tasks", json=task)
    if response.ok:
        print("成功更新任务错误状态")
        print(f"失败次数: {task['failed']}")
        print(f"错误信息: {task['lastErrorMsg']}")
    else:
        print(f"更新失败: {response.status_code}")
        print(response.text)

if __name__ == "__main__":
    simulate_task_error()
    print("现在刷新前端页面，应该能看到失败统计了！")
